#初始化celery
# import os
# from celery import Celery

# # 必须在实例化celery应用对象之前执行
# os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'demo038.settings')
#
# # 实例化celery应用对象
# app = Celery('demo0328')
# # 指定任务的队列名称
# app.conf.task_default_queue = 'Celery'
# # 也可以把配置写在django的项目配置中
# app.config_from_object('django.conf:settings', namespace='CELERY') # 设置django中配置信息以 "CELERY_"开头为celery的配置信息
# # 自动根据配置查找django的所有子应用下的tasks任务文件
# app.autodiscover_tasks()

# proj/celery.py
import os
from celery import Celery
#修改的配置文件
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'fuguang.settings.dev')
#改名
app = Celery('fuguang')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()


#定时任务配置
from celery.schedules import crontab
app.conf.beat_schedule = {
    'add-every-30-seconds': {
        'task': 'user.tasks.say',#哪个文件下的函数
        'schedule': 30.0,#设置时间  可以是秒数  可以是周几  可以几点
        #'schedule': crontab(hour=2, minute=0),  # 每天凌晨2点
        #'schedule': crontab(hour=9, minute=0, day_of_week=1),  # 周一9点
        #'args': ('张三')#任务函数需要的参数  如果没有参数可以不用谢
    },
}